package com.mdp.im.core.scbscriber.api;

/**
 * im内部通讯模型-从队列获取需要入库的消息，存入数据库
 * 订阅者接口,独占消息
 * 
 * @author chenyc
 * @date 2020/3/28
 */
public interface StoreSubscriber {

    /**
     * 接收系统消息数据
     * @param message
     */
    void onSysMessageFromDbQueue(String message);

    /**
     * 接收私人聊天数据
     * @param message
     */
    void onPrichatMessageFromDbQueue(String message);
    
    /**
     * 接收群组相关数据
     * @param message
     */
    void onGroupMessageFromDbQueue(String message);


    
    /**
     * 启动 系统消息订阅器查阅待插入数据库的系统消息
     */
    void startSysMessageSubscriberFromDbQueue();

    
    /**
     * 启动 接收私人聊天数据的订阅器查阅待插入数据库的私聊消息
     */
    void startPrichatMessageSubscriberFromDbQueue();
    
    /**
     * 启动 接收群组相关数据的订阅器查阅待插入数据库的群聊消息
     */
    void startGroupMessageSubscriberFromDbQueue();
}
